package org.chnxi.study.messagequeue.kafka.comsumer;

import org.apache.kafka.clients.consumer.KafkaConsumer;

public interface PollMsgProcessor<K,V> {

    public void pollMsg(KafkaConsumer<K,V> consumer);

}
